package com.shujia.flink.function;

import org.apache.flink.table.functions.ScalarFunction;

/**
 * @author shujia
 */
public class SplitFunction extends ScalarFunction {
    public String[] eval(String line, String sep) {
        return line.split(sep);
    }
}
